package com.pphh.demo;

import io.reactivex.Flowable;
import io.reactivex.Observable;

/**
 * Please add description here.
 *
 * @author huangyinhuang
 * @date 9/3/2018
 */
public class HelloWorld {

    public static void main(String[] args) throws InterruptedException {
        Flowable.just("Hello world").subscribe(System.out::println);
        Observable.fromArray("a", "b", "c").subscribe(System.out::println);
    }

}
